package com.lost.octopus.es.processor.dao.mapper.mybatis;


import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param;

import java.util.List;

/**
 * 同步基础数据接口（只要是基础数据ID自增即可使用）
 * 如非基础同步实体，不必继承
 * @author zhangbh
 */
public interface BaseAsyncMapper<T> extends BaseMapper<T> {

    /**
     * 获取同步es主表自增键，有效数据
     */
    List<Integer> scrollMainTabIds(Integer maxId, Integer pageSize);

    /**
     * 获取待同步信息（有效）
     * @param data 查询对象
     * @return 待同步信息
     */
    List<T> findWillSyncInfo(@Param("data") List<Integer> data);


}
